package com.tuniu.agents.common.handler;

import reactor.core.publisher.Flux;

import java.util.Map;

/**
 * Stream Response Handler Interface
 * Defines the basic methods for handling streaming content
 */
public interface IStreamResponseHandler {

    /**
     * Handles streaming data
     * @param handlerContext the context for the handler
     * @param flux the stream of data to handle
     * @return a Flux of processed strings
     */
    Flux<String> handle(Map<String, Object> handlerContext, Flux<String> flux);

}